package com.tensai.study.java.newconcept.typereactiveprogram.reactor.flux;

import com.tensai.study.java.newconcept.typereactiveprogram.reactor.schedule.ScheduleTest;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;

/**
 * subscribeOn是用来切换Subscriber的执行上下文，
 * 不管subscribeOn出现在调用链的哪个部分，最终都会应用到整个调用链上。
 *
 * @author Tensai
 */
@Slf4j
public class SubscribeOnTest {

	/**
	 * @see ScheduleTest#subscribeOnTest()
	 */
	@Test
	public void useSubscribeOn() throws InterruptedException {
		new ScheduleTest().subscribeOnTest();
	}

}
